package com.jgp.sys.utils;

import org.springframework.messaging.simp.SimpMessagingTemplate;

/**
 * 项目   jgp-cloud-parent
 * 作者   loufei
 * 时间   2019/1/30
 */
public class SocketUtil {
    
    /**
     * 广播
     * @param subscribe
     * @param data
     */
    public static void send(String subscribe,Object data){
        SimpMessagingTemplate messagingTemplate = SpringContextUtil.getBean(SimpMessagingTemplate.class);
        messagingTemplate.convertAndSend("/topic"+subscribe, data);
    }
    
    /**
     * 给指定端点发送消息
     * @param userKey
     * @param subscribe
     * @param data
     */
    public static void sendToPoint(String userKey,String subscribe,Object data){
        SimpMessagingTemplate messagingTemplate = SpringContextUtil.getBean(SimpMessagingTemplate.class);
        messagingTemplate.convertAndSendToUser(userKey,subscribe, data);
    }
    
}
